const ws = require("ws");
const sock = new ws("ws://127.0.0.1:5555");
const constant = require('./src/constant')
const method = require('./src/method')

sock.on("open", function () {
  console.log("微信连接成功!");
});
// 与微信连接发生错误的回调函数
sock.on("error", function (err) {
  console.log('微信断开连接');
});
// 主动与微信断开连接的回调函数
sock.on("close", function () {
  console.log('微信断开连接');
});

sock.on("message", function (msg) {
  const data = JSON.parse(msg.toString());
  console.log('接收到消息:', data.content);
  switch (data.type) {
    case constant.PERSONAL_INFO: //收到个人信息
      break;
    case constant.HEART_BEAT: //收到心跳
      break;
    case constant.PERSONAL_INFO: // 自己的消息
      break;
    case constant.RECV_TXT_MSG: //收到文字消息
      method.handle_recv_msg(data);
      break;
    case constant.RECV_PIC_MSG: //收到图片消息
      //不予理会
      break;
    case constant.USER_LIST: // 获取联系列表
      break;
    case constant.GH_MESSAGE: // 公众号xml消息
    default:
      break;
  }
});


